57ad943502103a60cc415081574c0efa37fab39e,graylog2-server/src/main/java/org/graylog2/buffers/ProcessBuffer.java,ProcessBuffer,initialize,#,73

Before Change


        Disruptor<MessageEvent> disruptor = new Disruptor<MessageEvent>(
                MessageEvent.EVENT_FACTORY,
                executor,
                new MultiThreadedClaimStrategy(server.getConfiguration().getRingSize()),
                server.getConfiguration().getProcessorWaitStrategy()
        );
        

After Change


    public void initialize() {
        Disruptor disruptor = new Disruptor<MessageEvent>(
                MessageEvent.EVENT_FACTORY,
                server.getConfiguration().getRingSize(),
                executor,
                ProducerType.MULTI,
                server.getConfiguration().getProcessorWaitStrategy()